package com.lvy.hczn.front.business.service;

import org.apache.rocketmq.common.message.MessageExt;

public interface ConsumeService {

    /**
     * 同步表的消息消费
     *
     * @param message
     * @return
     * @author yw
     * @date 2021-06-28 12:27:12
     */
    void doBusiness(MessageExt message) throws Exception;
}
